package com.kqkj.dyrule.marketing.functions;

import com.alibaba.fastjson.JSON;
import com.kqkj.dyrule.marketing.beans.EventBean;
import org.apache.flink.api.common.functions.MapFunction;

public class JsonEventBeanMapFunction implements MapFunction<String, EventBean> {
    @Override
    public EventBean map(String s) {
        EventBean eventBean = null;
        try{
            eventBean = JSON.parseObject(s, EventBean.class);
        } catch(Exception e){
        }
        return eventBean;
    }
}
